package cn.doitedu.day05

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.1
 * @Created by HANGGE
 * @Description
 */
object C16_转换算子_拉链 {
  def main(args: Array[String]): Unit = {

    val sc = SparkUtil.getSc
    // 要求每个分区中的元素的个数一致的
    // 所有的数据个数一致
    // 两个RDD的分区数一致  分区内的数据个数一致
    val rdd1 = sc.makeRDD(List("办公用品" , "生活用品" , "精品箱包" ,"精品男装"),1)
    val rdd2 = sc.makeRDD(List("多易牌打印机","雕牌卫生纸" , "DOIT皮包公司" , "劲霸短裤"),1)
   /* val res = rdd1.zip(rdd2)
    res.foreach(println)*/
   // 和编号zip
    val res = rdd1.zipWithIndex()
    res.foreach(println)
  }
}
